package com.practice.bootdemo.common;
/*

import org.java_websocket.handshake.ServerHandshake;
import org.springframework.stereotype.Component;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.net.URISyntaxException;

public class MyWebSocketClient extends WebSocketClient {

    public MyWebSocketClient(String uri) throws URISyntaxException {
        super(new URI(uri));
    }

    @Override
    public void onOpen(ServerHandshake handshakedata) {
        System.out.println("新连接已打开");
        // 可以在这里发送初始消息或执行其他操作
    }

    @Override
    public void onMessage(String message) {
        System.out.println("收到消息: " + message);
        // 处理接收到的消息
    }

    @Override
    public void onClose(int code, String reason, boolean remote) {
        System.out.println("连接已关闭: " + reason);
        // 连接关闭时的清理工作
    }

    @Override
    public void onError(Exception ex) {
        ex.printStackTrace();
        // 处理错误
    }

    // 你可以添加一个方法来启动客户端连接
    public void start() {
        connect(); // 调用connect()方法来启动连接
    }
}*/
